58ae6668c6097e0237a0cbf2233d3cf6aca77410,phoenix-core/src/it/java/org/apache/phoenix/end2end/SkipScanQueryIT.java,SkipScanQueryIT,testSkipScanIntersectionAtEnd,#,325
Before Change
public void testSkipScanIntersectionAtEnd() throws Exception {
Connection conn = DriverManager.getConnection(getUrl());
String tableName = generateUniqueName();
PreparedStatement stmt = conn.prepareStatement("create table " + tableName
+ "(pk1 UNSIGNED_TINYINT NOT NULL, pk2 UNSIGNED_TINYINT NOT NULL, pk3 UNSIGNED_TINYINT NOT NULL, kv VARCHAR "
+ "CONSTRAINT pk PRIMARY KEY (pk1, pk2, pk3)) SPLIT ON (?, ?, ?)");
stmt.setBytes(1, new byte[] {1, 1});
stmt.setBytes(2, new byte[] {2, 1});
stmt.setBytes(3, new byte[] {3, 1});
stmt.execute();
conn.createStatement().execute("upsert into " + tableName + " values (0, 1, 1, 'a')");
After Change
+ "CONSTRAINT pk PRIMARY KEY (pk1, pk2, pk3)) SPLIT ON ('"
+ Bytes.toString(new byte[] { 1, 1 }) + "', '"
+ Bytes.toString(new byte[] { 2, 1 }) + "', '"
+ Bytes.toString(new byte[] { 3, 1 }) + "')");
conn.createStatement().execute("upsert into " + tableName + " values (0, 1, 1, 'a')");
conn.createStatement().execute("upsert into " + tableName + " values (1, 1, 1, 'a')");